package cn.sx.stream.receiver.input;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface StreamInputSource {
    //和生产者相同点: 一个方法 绑定一个 通道名称 返回一个Channel
    //和生产者不同点: channel类型是订阅通道 注解使用@Input
    @Input("stream-receiver-input01")
    SubscribableChannel getStreamInput01();
    @Input("stream-receiver-input02")
    SubscribableChannel getStreamInput02();
}
